package neu.soft.rocket;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.stereotype.Component;

@Component
public interface OutputSource {
    @Output("to-operation_service")
    MessageChannel sendTrans();
    @Output("to-operation_service2")
    MessageChannel sendMoney();
    @Output("to_dispatch_service")
    MessageChannel sendCommon();
    @Output("to_dispatch_service2")
    MessageChannel sendReturn();
    @Output("to_financial_service3")
    MessageChannel sendExchange();

    @Input("listen-warehouse")
    SubscribableChannel listenLackSupply();

}
